<?php
/**
 * @version V5.06 16 Oct 2008  (c) 2000-2009 John Lim (jlim#natsoft.com). All rights reserved.
 * Released under both BSD license and Lesser GPL library license.
 * Whenever there is any discrepancy between the two licenses,
 * the BSD license will take precedence.
 *
 * Set tabs to 4 for best viewing.
 *
 * PEAR DB Emulation Layer for ADODB.
 *
 * The following code is modelled on PEAR DB code by Stig Bakken <ssb@fast.no>								   |
 * and Tomas V.V.Cox <cox@idecnet.com>.	Portions (c)1997-2002 The PHP Group.
 */

/*
 We support:

 DB_Common
 ---------
 query - returns PEAR_Error on error
 limitQuery - return PEAR_Error on error
 prepare - does not return PEAR_Error on error
 execute - does not return PEAR_Error on error
 setFetchMode - supports ASSOC and ORDERED
 errorNative
 quote
 nextID
 disconnect

 getOne
 getAssoc
 getRow
 getCol
 getAll

 DB_Result
 ---------
 numRows - returns -1 if not supported
 numCols
 fetchInto - does not support passing of fetchmode
 fetchRows - does not support passing of fetchmode
 free
 */

define('ADODB_PEAR',dirname(__FILE__));
include_once "PEAR.php";
include_once ADODB_PEAR."/adodb-errorpear.inc.php";
include_once ADODB_PEAR."/adodb.inc.php";

if (!defined('DB_OK')) {
    define("DB_OK",	1);
    define("DB_ERROR",-1);

    // autoExecute constants
    define('DB_AUTOQUERY_INSERT', 1);
    define('DB_AUTOQUERY_UPDATE', 2);

    /**
     * This is a special constant that tells DB the user hasn't specified
     * any particular get mode, so the default should be used.
     */

    define('DB_FETCHMODE_DEFAULT', 0);

    /**
     * Column data indexed by numbers, ordered from 0 and up
     */

    define('DB_FETCHMODE_ORDERED', 1);

    /**
     * Column data indexed by column names
     */

    define('DB_FETCHMODE_ASSOC', 2);

    /* for compatibility */

    define('DB_GETMODE_ORDERED', DB_FETCHMODE_ORDERED);
    define('DB_GETMODE_ASSOC',   DB_FETCHMODE_ASSOC);

    /**
     * these are constants for the tableInfo-function
     * they are bitwised or'ed. so if there are more constants to be defined
     * in the future, adjust DB_TABLEINFO_FULL accordingly
     */

    define('DB_TABLEINFO_ORDER', 1);
    define('DB_TABLEINFO_ORDERTABLE', 2);
    define('DB_TABLEINFO_FULL', 3);
}

/**
 * The main "DB" class is simply a container class with some static
 * methods for creating DB objects as well as some utility functions
 * common to all parts of DB.
 *
 */

class DB
{
    /**
     * Create a new DB object for the specified database type
     *
     * @param $type string database type, for example "mysql"
     *
     * @return object a newly created DB object, or a DB error code on
     * error
     */

    function factory($type)
    {
        include_once(ADODB_DIR."/drivers/adodb-$type.inc.php");
        $obj = NewADOConnection($type);
        if (!is_object($obj)) $obj = new PEAR_Error('Unknown Database Driver: '.$dsninfo['phptype'],-1);
        return $obj;
    }

    /**
     * Create a new DB object and connect to the specified database
     *
     * @param $dsn mixed "data source name", see the DB::parseDSN
     * method for a description of the dsn format.  Can also be
     * specified as an array of the format returned by DB::parseDSN.
     *
     * @param $options mixed if boolean (or scalar), tells whether
     * this connection should be persistent (for backends that support
     * this).  This parameter can also be an array of options, see
     * DB_common::setOption for more information on connection
     * options.
     *
     * @return object a newly created DB connection object, or a DB
     * error object on error
     *
     * @see DB::parseDSN
     * @see DB::isError
     */
    function connect($dsn, $options = false)
    {
        if (is_array($dsn)) {
            $dsninfo = $dsn;
        } else {
            $dsninfo = DB::parseDSN($dsn);
        }
        switch ($dsninfo["phptype"]) {
            case 'pgsql': 	$type = 'postgres7'; break;
            case 'ifx':		$type = 'informix9'; break;
            default: 		$type = $dsninfo["phptype"]; break;
        }

        if (is_array($options) && isset($options["debug"]) &&
        $options["debug"] >= 2) {
            // expose php errors with sufficient debug level
            @include_once("adodb-$type.inc.php");
        } else {
            @include_once("adodb-$type.inc.php");
        }

        @$obj = NewADOConnection($type);
        if (!is_object($obj)) {
            $obj = new PEAR_Error('Unknown Database Driver: '.$dsninfo['phptype'],-1);
            return $obj;
        }
        if (is_array($options)) {
            foreach($options as $k => $v) {
                switch(strtolower($k)) {
                    case 'persist':
                    case 'persistent': 	$persist = $v; break;
                    #ibase
                    case 'dialect': 	$obj->dialect = $v; break;
                    case 'charset':		$obj->charset = $v; break;
                    case 'buffers':		$obj->buffers = $v; break;
                    #ado
                    case 'charpage':	$obj->charPage = $v; break;
                    #mysql
                    case 'clientflags': $obj->clientFlags = $v; break;
                }
            }
        } else {
            $persist = false;
        }

        if (isset($dsninfo['socket'])) $dsninfo['hostspec'] .= ':'.$dsninfo['socket'];
        else if (isset($dsninfo['port'])) $dsninfo['hostspec'] .= ':'.$dsninfo['port'];

        if($persist) $ok = $obj->PConnect($dsninfo['hostspec'], $dsninfo['username'],$dsninfo['password'],$dsninfo['database']);
        else  $ok = $obj->Connect($dsninfo['hostspec'], $dsninfo['username'],$dsninfo['password'],$dsninfo['database']);

        if (!$ok) $obj = ADODB_PEAR_Error();
        return $obj;
    }

    /**
     * Return the DB API version
     *
     * @return int the DB API version number
     */
    function apiVersion()
    {
        return 2;
    }

    /**
     * Tell whether a result code from a DB method is an error
     *
     * @param $value int result code
     *
     * @return bool whether $value is an error
     */
    function isError($value)
    {
        if (!is_object($value)) return false;
        $class = strtolower(get_class($value));
        return $class == 'pear_error' || is_subclass_of($value, 'pear_error') ||
        $class == 'db_error' || is_subclass_of($value, 'db_error');
    }


    /**
     * Tell whether a result code from a DB method is a warning.
     * Warnings differ from errors in that they are generated by DB,
     * and are not fatal.
     *
     * @param $value mixed result value
     *
     * @return bool whether $value is a warning
     */
    function isWarning($value)
    {
        return false;
        /*
         return is_object($value) &&
         (get_class( $value ) == "db_warning" ||
         is_subclass_of($value, "db_warning"));*/
    }

    /**
     * Parse a data source name
     *
     * @param $dsn string Data Source Name to be parsed
     *
     * @return array an associative array with the following keys:
     *
     *  phptype: Database backend used in PHP (mysql, odbc etc.)
     *  dbsyntax: Database used with regards to SQL syntax etc.
     *  protocol: Communication protocol to use (tcp, unix etc.)
     *  hostspec: Host specification (hostname[:port])
     *  database: Database to use on the DBMS server
     *  username: User name for login
     *  password: Password for login
     *
     * The format of the supplied DSN is in its fullest form:
     *
     *  phptype(dbsyntax)://username:password@protocol+hostspec/database
     *
     * Most variations are allowed:
     *
     *  phptype://username:password@protocol+hostspec:110//usr/db_file.db
     *  phptype://username:password@hostspec/database_name
     *  phptype://username:password@hostspec
     *  phptype://username@hostspec
     *  phptype://hostspec/database
     *  phptype://hostspec
     *  phptype(dbsyntax)
     *  phptype
     *
     * @author Tomas V.V.Cox <cox@idecnet.com>
     */
    function parseDSN($dsn)
    {
        if (is_array($dsn)) {
            return $dsn;
        }

        $parsed = array(
			'phptype'  => false,
			'dbsyntax' => false,
			'protocol' => false,
			'hostspec' => false,
			'database' => false,
			'username' => false,
			'password' => false
        );

        // Find phptype and dbsyntax
        if (($pos = strpos($dsn, '://')) !== false) {
            $str = substr($dsn, 0, $pos);
            $dsn = substr($dsn, $pos + 3);
        } else {
            $str = $dsn;
            $dsn = NULL;
        }

        // Get phptype and dbsyntax
        // $str => phptype(dbsyntax)
        if (preg_match('|^(.+?)\((.*?)\)$|', $str, $arr)) {
            $parsed['phptype'] = $arr[1];
            $parsed['dbsyntax'] = (empty($arr[2])) ? $arr[1] : $arr[2];
        } else {
            $parsed['phptype'] = $str;
            $parsed['dbsyntax'] = $str;
        }

        if (empty($dsn)) {
            return $parsed;
        }

        // Get (if found): username and password
        // $dsn => username:password@protocol+hostspec/database
        if (($at = strpos($dsn,'@')) !== false) {
            $str = substr($dsn, 0, $at);
            $dsn = substr($dsn, $at + 1);
            if (($pos = strpos($str, ':')) !== false) {
                $parsed['username'] = urldecode(substr($str, 0, $pos));
                $parsed['password'] = urldecode(substr($str, $pos + 1));
            } else {
                $parsed['username'] = urldecode($str);
            }
        }

        // Find protocol and hostspec
        // $dsn => protocol+hostspec/database
        if (($pos=strpos($dsn, '/')) !== false) {
            $str = substr($dsn, 0, $pos);
            $dsn = substr($dsn, $pos + 1);
        } else {
            $str = $dsn;
            $dsn = NULL;
        }

        // Get protocol + hostspec
        // $str => protocol+hostspec
        if (($pos=strpos($str, '+')) !== false) {
            $parsed['protocol'] = substr($str, 0, $pos);
            $parsed['hostspec'] = urldecode(substr($str, $pos + 1));
        } else {
            $parsed['hostspec'] = urldecode($str);
        }

        // Get dabase if any
        // $dsn => database
        if (!empty($dsn)) {
            $parsed['database'] = $dsn;
        }

        return $parsed;
    }

    /**
     * Load a PHP database extension if it is not loaded already.
     *
     * @access public
     *
     * @param $name the base name of the extension (without the .so or
     * .dll suffix)
     *
     * @return bool true if the extension was already or successfully
     * loaded, false if it could not be loaded
     */
    function assertExtension($name)
    {
        if (!extension_loaded($name)) {
            $dlext = (strncmp(PHP_OS,'WIN',3) === 0) ? '.dll' : '.so';
            @dl($name . $dlext);
        }
        if (!extension_loaded($name)) {
            return false;
        }
        return true;
    }
}

?>